const mysql = require('mysql');
module.exports = {
	//数据库配置
	config:{
		host     : 'localhost',
		post     : '3306',
		user     : 'xxxx',
		password : 'xxxx',
		database : 'xxxx'
	},
	//连接数据库(连接池)
	//连接池对象
	sqlConnection:function(sql,sqlArr,cb){
		//连接池，数据很大，减少数据查询时间
		var pool = mysql.createPool(this.config);
		pool.getConnection((err,conn)=>{
			if(err){
				console.log('链接失败');
				return;
			}
			// console.log('链接成功');
			//事件驱动回调
			conn.query(sql,sqlArr,cb);
			//释放链接
			    conn.release();
			//此处可能会有问题，释放掉该链接
			// set global wait_timeout = 10;
		})
	},
	//promise回调
	SySqlConnect:function(sySql,sqlArr){
		return new Promise((resolve,reject)=>{
			var pool = mysql.createPool(this.config);
			pool.getConnection((err,conn)=>{
				if(err){
					reject(err)
				}else{
					conn.query(sySql,sqlArr,(err,data)=>{
						if(err){
							reject(err)
						}else{
							resolve(data)
						}
					});
					//释放链接
					    conn.release();
				}
			})
		}).catch((err)=>{
			console.log(err);
		})
	}
}